package ru.gerunn.test.thread;

public class T1 implements Runnable {

	private MyQueue<String> queue;

	public T1(MyQueue<String> queue) {
		this.queue = queue;
	}

	public void run() {
		while (true) {
			queue.add("T1");
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}

}
